package bsp.diff;

import org.apache.commons.functor.Function;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;

import util.ScanMessage;
import util.functors.OpScan;
import bsp.BspHelper;

public abstract class BspDiffHelper extends BspHelper<LongWritable, Text, Text, NullWritable, ScanMessage> {

	protected String inputPath;
	protected String outputPath;
	protected OpScan<? extends Number > oplus;
	protected OpScan<? extends Number > otimes;
	protected static Number cons_c;
	
	public Function<? extends Number> f;
	public Function<? extends Number> g;
	
	
	
	public abstract void setOperators();
	public BspDiffHelper(){
		//BspDiffHelper(cons_c);
		setOperators();
	}
	
	@Override
	public void setAllCMappers() {
 	//	this.addMapper(new ScanStepOne(oplus)); //oplus
    // 	this.addMapper(new ScanStepTwo(oplus));
		
	}
}